package com.ruoyi.framework.mqtt.handler;

import org.springframework.messaging.Message;
import org.springframework.messaging.MessagingException;

public interface MessageHandler {
    /**
     * 处理mqtt订阅接收的消息
     *
     * @param message
     * @param topic
     * @param msg
     * @throws MessagingException
     */
    void handleMessage(Message message, String topic, String msg) throws MessagingException;
}
